package com.zsy.rocketconsumerdemo.consumer;

import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.springframework.stereotype.Component;

@Component
public class ZsyOneWayConsumer extends BaseConsumer {

    public ZsyOneWayConsumer() {
        tag = "zsyOneWay";
    }

    @Override
    protected MessageListenerConcurrently obtainMessageListener() {
        return super.obtainMessageListener();
    }
}
